package io.gitee.redismq.core.annotation;

import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
/**
 * @Author: 孙浩
 * @CreateTime: 2025-03-05 13:50:28
 */
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface StreamListener {
    /**
     *  监听的 Stream Key（支持 SpEL 表达式）
     */
    String streamKey();
    /**
     * 消费者组名（支持 SpEL）
     */
    String groupName();
    /**
     * 消费者名称
     */
    String consumerName() default "default-consumer";
}
